let mysql=require('mysql')
let options={
    host:'localhost',
    port:'3306',
    user:'root',
    password:'123456',
    database:'xtjdb'
}
//创立连接
let con=mysql.createConnection(options)
//连接数据库
con.connect((err)=>{
    if(err){
        console.log(err);
        
    }else{
        console.log('数据库连接成功');
        
    }
})

//sql语句处理 (包装成promise)
function sqlQuery(sqlStr,arr){
    return new Promise((resolve,reject)=>{
        con.query(sqlStr,arr,(err,results)=>{
            if(err){
                reject(err)
            }else{
                resolve(results)
            }
        })
    }).catch((error) => {
        console.error(error);
      })
}
module.exports=sqlQuery
